package main

import (
	"fmt"
	"github.com/Shopify/sarama"
)

func main() {

	var topics = []string{"topic1"}
	AddController("topic1", func(message *sarama.ConsumerMessage) {
		fmt.Println(string(message.Value))
	})
	StartKafkaConsumer(topics)

	<-make(chan int)
}
